package org.study.hadoop.md.ch3;

import org.apache.hadoop.conf.Configured;
import org.apache.hadoop.filecache.DistributedCache;
import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.util.Tool;
import org.apache.hadoop.util.bloom.BloomFilter;

import java.io.IOException;
import java.net.URI;

/**
 * 布隆过滤：给定一个用户评论的列表，过滤掉大部分没有包含特定关键词的评论
 */
public class BloomFilteringDriver extends Configured implements Tool {

    public static class BloomFilteringMapper extends Mapper<Object, Text, Text, NullWritable> {
        private BloomFilter filter = new BloomFilter();

        @Override
        protected void setup(Context context) throws IOException, InterruptedException {
        }
    }

    @Override
    public int run(String[] args) throws Exception {
        return 0;
    }

    public static void main(String[] args) {

    }
}
